package com.bossien.flink.interfaces;

/**
 * @author 胡春林
 * 执行器接口
 */
public interface IExecutionHandlerConfig<T> {

    <T> T addSource() throws Exception;
    //主要用于执行过滤,flatmap,map等
     T executeFilter(T t);
     //自己选择输出
     T addSkin(T t) throws  Exception;
}
